//package com.qth.valet.transfer;
//
//import com.alibaba.fastjson2.JSON;
//import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.redisson.api.RTopic;
//import org.redisson.api.RedissonClient;
//import org.springframework.data.redis.core.StringRedisTemplate;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.PostConstruct;
//
//@Slf4j
//@Component
//@RequiredArgsConstructor
//public class MessageTransfer {
//
//    private static final String TOPIC = "notice.topic";
//
//    private final RedissonClient redissonClient;
//
//    private final StringRedisTemplate stringRedisTemplate;
//
//    // 监听广播
//    @PostConstruct
//    public void lisMSG() {
//        RTopic rtopic = redissonClient.getTopic(TOPIC);
//        rtopic.addListener(String.class, (String, noticeStr) -> {
//            log.debug("收到广播消息：{}", JSON.toJSONString(noticeStr));
//        });
//    }
//
//    // redisson 广播发消息
//    public void sendMSG(String noticeStr) {
//        RTopic rtopic = redissonClient.getTopic(TOPIC);
//        rtopic.publish(noticeStr);
//        log.debug("发送广播消息：{}", JSON.toJSONString(noticeStr));
//    }
//
//}
